package com.ws.common.constant;

/**
 * @Description: 审批状态
 * @Author LF
 * @Date 2020/4/26
 * @Version V1_0
 **/
public class Constant {

    //kafka properties
    public static final String kafka_producer_bootstrap_servers = "172.168.101.1:9092";
    public static final String kafka_producer_acks = "1";
    public static final String kafka_producer_buffer_memory = "33554432";
    public static final String kafka_producer_batch_size = "16384";
    public static final String kafka_producer_retries = "1";
    public static final String kafka_producer_linger_ms = "0";
    //发送失败等待时间                                                                                                                ;
    public static final String kafka_producer_request_timeout = "500";
    /*public static final String kafka_producer_key_serializer = "org_apache_kafka_common_serialization_StringSerializer";
    public static final String kafka_producer_value_serializer = "org_apache_kafka_common_serialization_StringSerializer";*/
    public static final String kafka_producer_key_serializer = "org.apache.kafka.common.serialization.StringSerializer";
    public static final String kafka_producer_value_serializer = "org.apache.kafka.common.serialization.StringSerializer";

    public static final String kafka_producer_key_deserializer = "org.apache.kafka.common.serialization.StringDeserializer";
    public static final String kafka_producer_value_deserializer = "org.apache.kafka.common.serialization.StringDeserializer";

    public static final String kafka_producer_topic = "gjsj";
    public static final String kafka_gjsjzd_topic = "gjsjzd";
    public static final String kafka_gjsjsj_topic = "gjsjsj";
    public static final String kafka_czcgj_topic = "czcgj";
    //kafka的华为认证                                                                                                              ;
    //增加kafka_client_security_mode=yes ，则激活kafka安全认证                                                                          ;
    public static final String kafka_client_security_mode = "no";
    //kafka kerberos认证协议                                                                                                      ;
    public static final String kafka_security_protocol = "SASL_PLAINTEXT";
    //kafka的此处配置kafka指向jaas_conf文件中的kafkaClient模块                                                                             ;
    public static final String kafka_sasl_kerberos_service_name = "kafka";
    //kafka认证需要的域名                                                                                                            ;
    public static final String kafka_kerberos_domain_name = "hadoop_hd_com";

}
